#include "../mqserver/mq_channel.hpp"

int main()
{
    ns_kkymq::ChannelManager::ptr cmp = std::make_shared<ns_kkymq::ChannelManager>();

    cmp->openChannel("c1", std::make_shared<ns_kkymq::VirtualHost>("host1", "./data/host1/message", "./data/host1/host1.db"),
                     std::make_shared<ns_kkymq::ConsumerManager>(),
                     ns_kkymq::ProtobufCodecPtr(),
                     muduo::net::TcpConnectionPtr(), threadpool::ptr());
    return 0;
} 